38b524f9b1e54195927fdfbf4b85148f1e777c6d,src/frontend/org/voltdb/iv2/FragmentTask.java,FragmentTask,processFragmentTask,#SiteProcedureConnection#,69
Before Change
// to the ee interface layer.. (rtb: not sure what 'this' encompasses...)
// (izzy: still not sure what 'this' encompasses...)
ParameterSet params = null;
final ByteBuffer paramData = m_task.getParameterDataForFragment(frag);
if (paramData != null) {
final FastDeserializer fds = new FastDeserializer(paramData);
try {
params = fds.readObject(ParameterSet.class);
}
catch (final IOException e) {
// IZZY: why not send a non-success response back to the
// MPI here?
hostLog.l7dlog(Level.FATAL,
LogKeys.host_ExecutionSite_FailedDeserializingParamsForFragmentTask.name(), e);
VoltDB.crashLocalVoltDB(e.getMessage(), true, e);
}
}
else {
params = new ParameterSet();
}
final int inputDepId = m_task.getOnlyInputDepId(frag);
After Change
final long fragmentId = m_task.getFragmentId(frag);
final int outputDepId = m_task.getOutputDepId(frag);
ParameterSet params = m_task.getParameterSetForFragment(frag);
final int inputDepId = m_task.getOnlyInputDepId(frag);
/*